2022-12-12版本

本文为您介绍2022年12月12日发布的实时计算Flink版的重大功能变更和主要缺陷修复。

概述

2022年12月12日正式对外发布实时计算Flink版的新版本。本次发布的是基于Apache Flink 1.15.2的VVR 6.0.3版本。该版本修复了一些Apache Flink社区的重大缺陷。同时平台新增了错误日志查询能力,您可以选择在日志中划词查询对应的异常。

说明

如果您的作业使用了VVR 6.0.3以下版本,建议您尽快将VVR版本升级至VVR 6.0.3,以确保生产的稳定运行。

功能介绍

  • 新增异常划词查询能力,您可以在作业运行事件、作业探查中找到相关日志,划词选中其中段落进行查询。通过查询您可以获取到错误原因和解决方案。

  • 支持增加或删除CDAS作业非空列的变更。

  • 在使用Kafka JSON Catalog推断Schema时,新增支持保持列的顺序一致。

  • 在写入MaxCompute数据时,支持可配置重试机制,以避免在Tunnel集群出现闪断情况,导致flink commit或者createuploadsession失败的问题。

  • 新增对于RDS 数据库创建新表错误语法的兼容能力,出现此类问题不再影响正在运行的Flink CDC任务。

  • 优化SQL语法校验的错误提示。

缺陷修复

  • 解决CDAS同步到Kafka时,sink.parallelism不生效的问题。

  • 修复6.0.2版本上CDAS作业ClassCastException报错问题。

  • 修复6.0.2版本上MySQL CDC源表延时曲线不显示的问题。

  • 修复6.0.2版本上SQL Hints语法不生效的问题。

  • 修复6.0.2版本上语法检查时将类冲突异常错误抛出为数据越界异常的问题。

  • 修复6.0.2版本上CTAS作业一张表写多个Sink时Server ID冲突的问题。

  • 修复部分情况下K8s leader选举造成的JM死锁的问题。

  • 修复状态后端Gemini的Decrease reference to an unknown file异常。